// ocr识别 消费者脚本
require('dotenv').config({ path: `./.env.${process.env.NODE_ENV.trim()}` }) // 环境变量注入
const { addAliases } = require('module-alias')
const path = require('path')
// 配置路径别名
addAliases({
    '@': path.resolve(__dirname, '../../src'),
})
const axios = require('axios')
const client = require('@/db/redis') // 用于执行其他命令的客户端
const redisSubscriber = require('@/db/redis-subscriber') // 用于订阅的客户端
const { BASE_URL, SERVICE_PORT, REDIS_DB } = process.env // 环境变量
const logger = require('@/utils/logger') // 日志记录

// 修改后的消费者逻辑
const { consumeMessages } = require('@/script/utils/redisLpush')
const QUEUE_NAME = 'ocr_queue' // 使用普通队列名

async function main() {
    consumeMessages(QUEUE_NAME, async (message) => {
        const data = JSON.parse(message)
        console.log('Received message:', message)
    })
}

main()
